package com.arch.flink.archetype.network.handler;

import org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext;
import org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter;

/**
 * @author pizhihui
 * @date 2024-05-20 18:07
 */
public class InboundEnvelopeDispatcher extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("服务端读取数据(dispatcher): " + msg);
    }
}
